package com.qfedu.edu.utils;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 线程池工具类
 * @author Administrator
 */
public class ThreadPoolUtils {

    /**
     * 异常处理线程池对象
     */
    private static ThreadPoolExecutor exceptionNotifyExecutor = new ThreadPoolExecutor(
            10, 100, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(8192));

    public static ThreadPoolExecutor getExceptionNotifyExecutor() {
        return exceptionNotifyExecutor;
    }
}
